Go语言网络编程

72次阅读
没有评论

共计 2986 个字符,预计需要花费 8 分钟才能阅读完成。

网络编程三要素:

  • IP 地址:通过 IP 地址找到指定计算机
  • 端口:通过端口找到指定进程
  • 协议:定义通信规则,符合协议则可以通信,不符合不能通信

TCP/IP 协议:

  • 建立连接:三次握手
  • 释放连接:四次挥手

TCP 编程

client\main.go

package main

import (
  "bufio"
  "fmt"
  "net"
  "os"
)

func main() {println(" 客户端启动...")
  conn, err := net.Dial("tcp", "127.0.0.1:8080") // 可简写为:8080,冒号前面默认是本机地址
  if err != nil {println(" 客户端连接失败:", err.Error())
    return
  }
  defer conn.Close()
  println(" 连接成功,conn:", conn.LocalAddr().String())

  // 客户端发送数据
  print(" 发送数据:")
  reader := bufio.NewReader(os.Stdin) // 从标准输入读取数据
  str, err := reader.ReadString('\n')
  if err != nil {println(" 终端输入数据失败:", err.Error())
    return
  }
  // 将 str 发送给服务端
  n, err := conn.Write([]byte(str))
  if err != nil {println(" 客户端发送数据失败:", err.Error())
  }

  fmt.Printf(" 客户端发送数据成功,一共发送了 %d 字节数据,并退出 ", n)
}

server\main.go

package main

import "net"

func process(conn net.Conn) {defer conn.Close()
  buf := make([]byte, 1024)
  n, err := conn.Read(buf) // 读取客户端数据,放入切片
  if err != nil {println(" 读取数据失败:", err.Error())
    return
  }
  println(" 接收到数据:", string(buf[:n]))
}

func main() {println(" 服务端启动...")
  listen, err := net.Listen("tcp", "127.0.0.1:8080")
  if err != nil {println(" 服务端监听失败:", err.Error())
    return
  }
  defer listen.Close()
  println(" 监听成功,listen:", listen.Addr().String())

  // 等待客户端连接
  for {conn, err := listen.Accept()
    if err != nil {println(" 客户端连接失败:", err.Error())
    } else {println(" 客户端连接成功:", conn.RemoteAddr().String())
      go process(conn) // 启动一个协程处理客户端请求
    }
  }
}

UDP 编程

server

package main

import (
  "fmt"
  "net"
)

func main() {listen, err := net.ListenUDP("udp", &net.UDPAddr{IP: net.IPv4zero, Port: 30000})
  if err != nil {fmt.Println("Listen error:", err)
    return
  }
  defer listen.Close()

  for {var data [1024]byte
    n, addr, err := listen.ReadFromUDP(data[:]) // 接收数据
    if err != nil {fmt.Println("ReadFromUDP error:", err)
      continue
    }
    fmt.Println("Received from", addr, "data:", string(data[:n]))

    _, err = listen.WriteToUDP([]byte("Hello, client!"), addr) // 发送数据
    if err != nil {fmt.Println("WriteToUDP error:", err)
      continue
    }
  }
}

client

package main

import (
  "fmt"
  "net"
)

func main() {
  socket, err := net.DialUDP("udp", nil, &net.UDPAddr{IP:   net.IPv4(0, 0, 0, 0),
    Port: 30000,
  })
  if err != nil {fmt.Println("Error connecting to server:", err)
    return
  }
  defer socket.Close()

  sendData := []byte("Hello, world!")
  _, err = socket.Write(sendData)
  if err != nil {fmt.Println("Error sending data to server:", err)
    return
  }

  data := make([]byte, 1024)
  n, _, err := socket.ReadFromUDP(data)
  if err != nil {fmt.Println("Error reading data from server:", err)
    return
  }
  fmt.Println("Received data from server:", string(data[:n]))
}

http 编程

client

package main

import (
  "fmt"
  "io"
  "net/http"
)

func main() {clint := http.Client{}
  resp, err := clint.Get("http://www.baidu.com")
  if err != nil {println("clint.Get error:", err)
    return
  }
  defer resp.Body.Close()

  fmt.Println(resp.Status)                     // 200 OK
  fmt.Println(resp.StatusCode)                 // 200
  fmt.Println(resp.Header.Get("Content-Type")) // application/x-gzip

  println(resp.Request.URL.String()) // http://www.baidu.com

  body, err := io.ReadAll(resp.Body)
  if err != nil {panic(err)
  }
  fmt.Println(string(body))
}

server

func main() {
  // 注册路由
  http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {fmt.Fprintln(w, " 主页 ")
  })
  http.HandleFunc("/name", func(w http.ResponseWriter, r *http.Request) {fmt.Fprintln(w, "name")
  })

  fmt.Println("http server start...")
  if err := http.ListenAndServe(":8080", nil); err != nil {fmt.Println("http start failed, err:", err)
    return
  }
}

正文完
 0
三毛笔记
版权声明:本站原创文章,由 三毛笔记 于2024-02-20发表,共计2986字。
转载说明:除特殊说明外本站文章皆由CC-4.0协议发布,转载请注明出处。
评论(没有评论)